2c9848214ad9782e3afe637193c0984d16ff49a1,src/main/java/net/jodah/recurrent/Recurrent.java,Recurrent,future,#Callable#RetryPolicy#Scheduler#,137

Before Change


  public static <T> java.util.concurrent.CompletableFuture<T> future(
      Callable<java.util.concurrent.CompletableFuture<T>> callable, RetryPolicy retryPolicy, Scheduler scheduler) {
    final java.util.concurrent.CompletableFuture<T> response = new java.util.concurrent.CompletableFuture<T>();
    call(AsyncCallable.ofFuture(callable), retryPolicy, scheduler, RecurrentFuture.of(response, scheduler, null), null);
    return response;
  }

After Change


    @Override
    @SuppressWarnings("unchecked")
    public <T> CompletableFuture<T> future(Callable<CompletableFuture<T>> callable) {
      java.util.concurrent.CompletableFuture<T> response = new java.util.concurrent.CompletableFuture<T>();
      call(AsyncContextualCallable.ofFuture(callable),
          RecurrentFuture.of(response, scheduler, (Listeners<T>) listeners));
      return response;
    }